package com.atguigu.activemq.Embed;

import org.apache.activemq.broker.BrokerService;

/**
 * @Auther 赵乾坤
 * @Date 2021-04-16 19:34
 */
public class EmbedBroker {
    public static void main(String[] args) throws Exception {
        //ActiveMQ也支持再VM中通信给予嵌入式的broker
        BrokerService brokerService = new BrokerService();
        brokerService.setUseJmx(true);
        brokerService.addConnector("tcp://localhost:61616");
        brokerService.start();
    }
}
